package com.bzframework.pro.socket.manager;

import com.bzframework.pro.socket.MessagingRequest;
import com.bzframework.pro.socket.message.Message;
import com.bzframework.pro.socket.provider.SubscribeRequest;
import reactor.core.publisher.Flux;

public interface MessagingManager {

    Flux<Message> subscribe(MessagingRequest request);

}
